package com.hub.realtime.sqlclient;


import com.hub.realtime.flinkshims.core.TableContext;
import com.hub.realtime.sqlclient.base.TableEnvInital;
import com.hub.realtime.sqlclient.base.model.FlinkRunEnv;

/**
 * sqlclient
 */
public class SqlClient {
    public static void main(String[] args) {
        FlinkRunEnv env = TableEnvInital.createEnv(args);
        TableContext tableContext=new TableContext(env.getParameterTool(),env.getSenv(),env.getTableEnvironment());
        tableContext.handelSql();
    }
}